package com.yundingai.service;

import com.yundingai.domain.vo.ChatVO;
import org.springframework.ai.chat.messages.Message;
import org.springframework.ai.chat.model.ChatResponse;
import reactor.core.publisher.Flux;

import java.util.List;

public interface ChatService {

    Flux<ChatResponse> chatStream(ChatVO chatVO);

    Flux<ChatResponse> streamMessage(ChatVO chatVO);
    List<Message> getChatMessages(String sessionId);

    void removeChatMessages(String sessionId);

    Flux<String> testStream(String question, String sessionId);

    void removeByMessageId(String sessionId, String messageId);
}
